package my.framework.ssm.sample.common.mq.redis;

import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;

/**
 * redis 消息发送器
 *
 * @author NuKI
 * @date 2018/11/25 14:02
 */
@Log4j2
@Component
public class RedisMqSender {
    @Autowired
    StringRedisTemplate redisTemplate;

    /**
     * @param topic   消息发布订阅 主题
     * @param message 消息信息
     * @author 七脉 描述：发布方法
     */
    public void send(String topic, Object message) {
        // 该方法封装的 connection.send(rawChannel, rawMessage);
        redisTemplate.convertAndSend(topic, message);
        log.info("主题【{}】消息【{}】发送成功", topic, message);
    }
}
